/*
	处理定时任务，包括数据库，Redis，Mq，日志文件等
*/
package cron

import (
	"github.com/robfig/cron"
	"micro-member/services"
)

//初始化定时任务
func InitCron() {
	//初始化定时任务service
	//cronService := services.NewCronService()
	channel := make(chan int,1)
	c := cron.New()
	//c.AddFunc("0 30 * * * *", func() { fmt.Println("Every hour on the half hour") })
	//c.AddFunc("@hourly",      func() { fmt.Println("Every hour") })
	//c.AddFunc("@every 1h30m", func() { fmt.Println("Every hour thirty") })

	// 定时每日，每23:59:59秒执行清空今日点击
	c.AddFunc("59 59 23 * * *", func() {
		//cronService.RunCleanTodayRank()
	})
	// 定时每周，每周日23:59:59秒执行清空本周点击
	c.AddFunc("59 59 23 * * 0", func() {
		//cronService.RunCleanWeekRank()
	})

	// 开始
	c.Start()

	// 函数将在它们自己的goroutine中异步调用

	// 也可以在运行的Cron中添加任务
	//c.AddFunc("@daily", func() { fmt.Println("Every day") })

	// 检查cron任务条目的下一个和上一个运行时间
	// inspect(c.Entries())

	//defer c.Stop()  // 停止定时任务(不停止已经运行的任务)
	<-channel
}


//处理MQ消费者数据
func InitConsumer(num int) {
	//消费爬虫金融文章
	mqService := services.NewRabbitmqService()
	mqService.PullConfirmPost(num)
}

